package com.qch.concurrent.demo_04_notify_consumer;

/**
 * @Author qch
 * @Date 2021/7/26
 */
public class Main2 {
    public static void main(String[] args) throws InterruptedException {
        MyQueue2 myQueue2 = new MyQueue2();
        for (int i = 0; i < 5; i++) {
            new ConsumerThread(myQueue2).start();
            new ProducerThread(myQueue2).start();
        }
        Thread.sleep(5000);
        //进程退出
        System.exit(0);
    }
}
